package com.eastfair.comsumer;

import com.alibaba.fastjson.JSONObject;
import com.eastfair.core.point.BasePoint;
import com.eastfair.point.PointKeyDefinition;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class ComsumerController {

    @KafkaListener(topics = "test",groupId = "${spring.application.name}")
    public void onMessage(String message) {
        System.out.println("收到消息 is "+message);
    }
}
